package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.api.scala._

/**
 * rebalance（再平衡，用来减轻数据倾斜）
 *
 * @author ydl
 * @since 2020/10/14
 */
object RebalanceDemo extends App with Utils {
  val input = env.fromElements((1 to 100).toList)
  input.print()
  input.rebalance().print()
}
